package com.mgzf.bs.uploadCenter.service;

import com.mgzf.bs.uploadCenter.service.task.IMsgTask;

/**
 * Created by mike on 18/1/18.
 */
public interface IkafkaService {
    Boolean getRecvStopSign();

    void setRecvStopSign(Boolean jump);

    void receive(String topic, IMsgTask msgTask);
}
